package top.lingkang.potato.utils.rx;

import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;

/**
 * @author lingkang
 * @date 2021/9/19 23:36
 * @description
 */
public class ByWatch<T> implements ObservableOnSubscribe<T> {
    @Override
    public void subscribe(ObservableEmitter<T> emitter) throws Exception {

    }
}